package com.ocom.xcxapi.mq.config;

import com.ocom.amqp.core.DelayQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Description: TODO
 * @Author: 朱晖
 * @Date: 2022/7/3
 **/
@Configuration
public class ActiveQuiryQueueConfig {

	/**
	 * 参数名	释义	是否必填
	 * businessName	业务名称，RabbitMQ Virtual Host 中需保证唯一	是
	 * expiration	延时时间	否 如果不填，则需要开发者发送消息时，手动设置 MessageProperties 消息延时时间
	 * routingKey	路由键 禁止使用 '#'，'*' 模糊匹配字符	是
	 * 声明延时组件
	 * @return
	 */
	@Bean
	public DelayQueue delayQueue() {
		//10秒
//		DelayQueue queue = new DelayQueue("active-check-message", 10000l, "send");
		DelayQueue queue = new DelayQueue("wxsign-check-delay", 120000l, "send");
		return queue;
	}

}
